package com.atguigu.source



import org.apache.flink.streaming.api.scala._



object test {
  def main(args: Array[String]): Unit = {
    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    env.setParallelism(1)
    val value: DataStream[SensorReading] = env.addSource(new SensorSource)
    value.print()
    env.execute()
  }
}